package com.yt.Test;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;

import javax.swing.*;

public class Chats  extends JFrame{

	Socket socket;
	PrintWriter out;
	BufferedReader in;
	JPanel p;
	JScrollPane sp;
	JTextArea txtContent;
	JLabel lblName, lblSend;
	JTextField txtName , txtSend;
	JButton btnSend;
	

	public Chats(){
		super("客户聊天");
		txtContent = new JTextArea();
		//设置文本域只读
		txtContent.setEditable(false);
		sp = new JScrollPane(txtContent);
		
		lblName = new JLabel ("姓名:")	;
		txtName = new JTextField(5) ;
		lblSend = new JLabel("请输入:");
		txtSend = new JTextField(20);
		btnSend = new JButton("发送");
		
		p = new JPanel();
		p.add(lblName);
		p.add(txtName);
		p.add(lblSend);
		p.add(txtSend);
		p.add(btnSend);
		this.add(p,BorderLayout.SOUTH);
		
		this.add(sp);
		this.setSize(500,400);
		this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		try{
			//创建一个套接字
			socket = new Socket("192.168.199.154", 8080);
			//创建一个往套接字中写数据的通道，即输出流，给服务器发送信息
			out = new PrintWriter(socket.getOutputStream());
			//创建一个从套接字读取数据的通道，即输入流，读服务器的返回信息
			in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			
		}catch(UnknownHostException e){
			e.printStackTrace();
		}catch(IOException e){
			e.printStackTrace();
		}
		// 注册监听
		btnSend.addActionListener(new ActionListener(){
			public void actionPerformed( ActionEvent e){
				//获取用户输入的文本
				String strName = txtName.getText();
				String strMsg = txtSend.getText();
				if(!strMsg.equals("")){
					//通过输入流将数据发送给服务器
					out.println(strName +"说 :" +strMsg);
					out.flush();
					//清空文本框
					txtSend.setText("");
				}
			}

		});
		//启动线程
		new GetMsgFromServer().start();	
    }
	
	//接受服务器的返回信息
	class GetMsgFromServer extends Thread {
		public void run(){
			while ( this.isAlive() ){
				try{
					String strMsg = in.readLine();
					if(strMsg != null){
						//在文本域中显示聊天信息
						txtContent.append(strMsg+"\n");
					}
					Thread.sleep(50);
				}catch(Exception e){
					e.printStackTrace();
				}
			}
		}
	}
	
	public static void main(String[] args){
		Chats f = new Chats();
		f.setVisible(true);
	}
}